from kafka import KafkaConsumer

consumer = KafkaConsumer('test-non',bootstrap_servers='192.168.8.5:9092')

for message in consumer:
    print(f'Received message: {message.value.decode()}')